85b9b4c6798d29161b84901771c9b3e65e81289d,src/main/java/fr/pilato/elasticsearch/crawler/fs/client/ElasticsearchClient.java,ElasticsearchClient,bulk,#BulkRequest#,100

Before Change


        logger.trace("{}", sbf);

        StringEntity entity = new StringEntity(sbf.toString(), Charset.defaultCharset());
        Response restResponse = client.performRequest("POST", "/_bulk", Collections.emptyMap(), entity);
        BulkResponse response = JsonUtil.deserialize(restResponse, BulkResponse.class);
        logger.debug("bulk response: {}", response);
        return response;

After Change



        Map<String, String> params;

        if (pipeline != null) {
            params = new HashMap<>(1);
            params.put("pipeline", pipeline);
        } else {
            params = Collections.emptyMap();
        }

        StringEntity entity = new StringEntity(sbf.toString(), Charset.defaultCharset());